B C D E F G I M O P R S T W
All Classes All Packages

B

build() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

Builds the SingleStoreSchemaTransformReadConfiguration configuration.

build() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration.Builder

Builds the SingleStoreSchemaTransformWriteConfiguration configuration.

builder() - Static method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

Instantiates a SingleStoreSchemaTransformReadConfiguration.Builder.

builder() - Static method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration

Instantiates a SingleStoreSchemaTransformWriteConfiguration.Builder.

Builder() - Constructor for class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

Builder() - Constructor for class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration.Builder

C

configurationClass() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadProvider

Returns the expected class of the configuration.

configurationClass() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

Returns the expected class of the configuration.

create(String) - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

D

DataSourceConfiguration() - Constructor for class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

E

expand(PBegin) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

expand(PBegin) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

F

from(SingleStoreSchemaTransformReadConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadProvider

Returns the expected SchemaTransform of the configuration.

from(SingleStoreSchemaTransformWriteConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

Returns the expected SchemaTransform of the configuration.

G

getBatchSize() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration

getCoder() - Method in interface org.apache.beam.sdk.io.singlestore.SingleStoreIO.RowMapperWithCoder

getDataSource() - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

getDataSourceConfiguration() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

getDataSourceConfiguration() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration

getOutputParallelization() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

getQuery() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

getTable() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

getTable() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration

getWithPartitions() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

I

identifier() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadProvider

Implementation of the TypedSchemaTransformProvider identifier method.

identifier() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

Implementation of the TypedSchemaTransformProvider identifier method.

init(ResultSetMetaData) - Method in interface org.apache.beam.sdk.io.singlestore.SingleStoreIO.RowMapperWithInit

INPUT_TAG - Static variable in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

inputCollectionNames() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadProvider

Implementation of the TypedSchemaTransformProvider inputCollectionNames method.

inputCollectionNames() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

Implementation of the TypedSchemaTransformProvider inputCollectionNames method.

M

mapRow(ResultSet) - Method in interface org.apache.beam.sdk.io.singlestore.SingleStoreIO.RowMapper

mapRow(T) - Method in interface org.apache.beam.sdk.io.singlestore.SingleStoreIO.UserDataMapper

O

org.apache.beam.sdk.io.singlestore - package org.apache.beam.sdk.io.singlestore

Transforms for reading and writing from SingleStoreDB.

org.apache.beam.sdk.io.singlestore.schematransform - package org.apache.beam.sdk.io.singlestore.schematransform

SingleStoreIO SchemaTransforms.

outputCollectionNames() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadProvider

Implementation of the TypedSchemaTransformProvider outputCollectionNames method.

outputCollectionNames() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

Implementation of the TypedSchemaTransformProvider outputCollectionNames method.

P

populateDisplayData(SingleStoreIO.DataSourceConfiguration, DisplayData.Builder) - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

R

read() - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO

Read data from a SingleStoreDB datasource.

Read() - Constructor for class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

readRows() - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO

Read Beam Rows from a SingleStoreDB datasource.

readWithPartitions() - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO

Like SingleStoreIO.read(), but executes multiple instances of the query on the same table for each database partition.

ReadWithPartitions() - Constructor for class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

readWithPartitionsRows() - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO

Like SingleStoreIO.readRows(), but executes multiple instances of the query on the same table for each database partition.

S

setBatchSize(Integer) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration.Builder

setDataSourceConfiguration(SingleStoreIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

setDataSourceConfiguration(SingleStoreIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration.Builder

setOutputParallelization(Boolean) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

setParameters(PreparedStatement) - Method in interface org.apache.beam.sdk.io.singlestore.SingleStoreIO.StatementPreparator

setQuery(String) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

setTable(String) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

setTable(String) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration.Builder

setWithPartitions(Boolean) - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration.Builder

SingleStoreIO - Class in org.apache.beam.sdk.io.singlestore

IO to read and write data on SingleStoreDB.

SingleStoreIO() - Constructor for class org.apache.beam.sdk.io.singlestore.SingleStoreIO

SingleStoreIO.DataSourceConfiguration - Class in org.apache.beam.sdk.io.singlestore

A POJO describing a SingleStoreDB DataSource by providing all properties needed to create it.

SingleStoreIO.Read<T> - Class in org.apache.beam.sdk.io.singlestore

A PTransform for reading data from SingleStoreDB.

SingleStoreIO.Read.SingleStoreRowMapperInitializationException - Exception in org.apache.beam.sdk.io.singlestore

SingleStoreIO.ReadWithPartitions<T> - Class in org.apache.beam.sdk.io.singlestore

A PTransform for reading data from SingleStoreDB.

SingleStoreIO.RowMapper<T> - Interface in org.apache.beam.sdk.io.singlestore

An interface used by SingleStoreIO.Read and SingleStoreIO.ReadWithPartitions for converting each row of the ResultSet into an element of the resulting PCollection.

SingleStoreIO.RowMapperWithCoder<T> - Interface in org.apache.beam.sdk.io.singlestore

A RowMapper that provides a Coder for resulting PCollection.

SingleStoreIO.RowMapperWithInit<T> - Interface in org.apache.beam.sdk.io.singlestore

A RowMapper that requires initialization.

SingleStoreIO.StatementPreparator - Interface in org.apache.beam.sdk.io.singlestore

An interface used by the SingleStoreIO SingleStoreIO.Read to set the parameters of the PreparedStatement.

SingleStoreIO.UserDataMapper<T> - Interface in org.apache.beam.sdk.io.singlestore

An interface used by the SingleStoreIO SingleStoreIO.Write to map a data from each element of PCollection to a List of Strings.

SingleStoreIO.Write<T> - Class in org.apache.beam.sdk.io.singlestore

A PTransform for writing data to SingleStoreDB.

SingleStoreSchemaTransformReadConfiguration - Class in org.apache.beam.sdk.io.singlestore.schematransform

Configuration for reading from SingleStoreDB.

SingleStoreSchemaTransformReadConfiguration() - Constructor for class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

SingleStoreSchemaTransformReadConfiguration.Builder - Class in org.apache.beam.sdk.io.singlestore.schematransform

SingleStoreSchemaTransformReadProvider - Class in org.apache.beam.sdk.io.singlestore.schematransform

An implementation of TypedSchemaTransformProvider for SingleStoreDB read jobs configured using SingleStoreSchemaTransformReadConfiguration.

SingleStoreSchemaTransformReadProvider() - Constructor for class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadProvider

SingleStoreSchemaTransformWriteConfiguration - Class in org.apache.beam.sdk.io.singlestore.schematransform

Configuration for writing to SingleStoreDB.

SingleStoreSchemaTransformWriteConfiguration() - Constructor for class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration

SingleStoreSchemaTransformWriteConfiguration.Builder - Class in org.apache.beam.sdk.io.singlestore.schematransform

SingleStoreSchemaTransformWriteProvider - Class in org.apache.beam.sdk.io.singlestore.schematransform

An implementation of TypedSchemaTransformProvider for SingleStoreDB write jobs configured using SingleStoreSchemaTransformWriteConfiguration.

SingleStoreSchemaTransformWriteProvider() - Constructor for class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

T

toBeamRow() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

Serializes configuration to a Row.

toBeamRow() - Method in class org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteConfiguration

Serializes configuration to a Row.

W

withBatchSize(Integer) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

Provide a maximum number of rows that is written by one SQL statement.

withConnectionProperties(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

Sets the connection properties passed to driver.connect(...).

withDatabase(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

withDataSourceConfiguration(SingleStoreIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

withDataSourceConfiguration(SingleStoreIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

withDataSourceConfiguration(SingleStoreIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

withOutputParallelization(Boolean) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

Whether to reshuffle the resulting PCollection so results are distributed to all workers.

withPassword(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

withQuery(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

withQuery(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

withRowMapper(SingleStoreIO.RowMapper<T>) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

withRowMapper(SingleStoreIO.RowMapper<T>) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

withStatementPreparator(SingleStoreIO.StatementPreparator) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

withTable(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Read

withTable(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.ReadWithPartitions

withTable(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

withUserDataMapper(SingleStoreIO.UserDataMapper<T>) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

withUsername(String) - Method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

write() - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO

Write data to a SingleStoreDB datasource.

Write() - Constructor for class org.apache.beam.sdk.io.singlestore.SingleStoreIO.Write

writeRows() - Static method in class org.apache.beam.sdk.io.singlestore.SingleStoreIO

Write Beam Rows to a SingleStoreDB datasource.

B C D E F G I M O P R S T W
All Classes All Packages