org.apache.beam.sdk.io.jdbc

Interface JdbcReadWithPartitionsHelper<PartitionT>

Type Parameters:

PartitionT - Element type of the column used for partition.

All Superinterfaces:

JdbcIO.PreparedStatementSetter<KV<PartitionT,PartitionT>>, JdbcIO.RowMapper<KV<java.lang.Long,KV<PartitionT,PartitionT>>>, java.io.Serializable

public interface JdbcReadWithPartitionsHelper<PartitionT>
extends JdbcIO.PreparedStatementSetter<KV<PartitionT,PartitionT>>, JdbcIO.RowMapper<KV<java.lang.Long,KV<PartitionT,PartitionT>>>

A helper for JdbcIO.ReadWithPartitions that handles range calculations.

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<KV<PartitionT,PartitionT>>	calculateRanges(PartitionT lowerBound, PartitionT upperBound, java.lang.Long partitions) Calculate the range of each partition from the lower and upper bound, and number of partitions.
KV<java.lang.Long,KV<PartitionT,PartitionT>>	mapRow(java.sql.ResultSet resultSet)
void	setParameters(KV<PartitionT,PartitionT> element, java.sql.PreparedStatement preparedStatement)

Method Detail

calculateRanges

java.lang.Iterable<KV<PartitionT,PartitionT>> calculateRanges(PartitionT lowerBound,
                                                              PartitionT upperBound,
                                                              java.lang.Long partitions)

Calculate the range of each partition from the lower and upper bound, and number of partitions.

Return a list of pairs for each lower and upper bound within each partition.

setParameters

void setParameters(KV<PartitionT,PartitionT> element,
                   java.sql.PreparedStatement preparedStatement)

Specified by:

setParameters in interface JdbcIO.PreparedStatementSetter<KV<PartitionT,PartitionT>>

mapRow

KV<java.lang.Long,KV<PartitionT,PartitionT>> mapRow(java.sql.ResultSet resultSet)
                                             throws java.lang.Exception

Specified by:

mapRow in interface JdbcIO.RowMapper<KV<java.lang.Long,KV<PartitionT,PartitionT>>>

Throws:

java.lang.Exception