CassandraInputFormat(String query,
ClusterBuilder builder) |
CassandraInputFormatBase(String query,
ClusterBuilder builder) |
CassandraOutputFormat(String insertQuery,
ClusterBuilder builder)
Deprecated.
|
CassandraPojoInputFormat(String query,
ClusterBuilder builder,
Class<OUT> inputClass) |
CassandraPojoInputFormat(String query,
ClusterBuilder builder,
Class<OUT> inputClass,
MapperOptions mapperOptions) |
CassandraPojoOutputFormat(ClusterBuilder builder,
Class<OUT> outputClass) |
CassandraPojoOutputFormat(ClusterBuilder builder,
Class<OUT> outputClass,
MapperOptions mapperOptions) |
CassandraPojoOutputFormat(ClusterBuilder builder,
Class<OUT> outputClass,
MapperOptions mapperOptions,
int maxConcurrentRequests,
java.time.Duration maxConcurrentRequestsTimeout) |
CassandraRowOutputFormat(String insertQuery,
ClusterBuilder builder) |
CassandraRowOutputFormat(String insertQuery,
ClusterBuilder builder,
int maxConcurrentRequests,
java.time.Duration maxConcurrentRequestsTimeout) |
CassandraTupleOutputFormat(String insertQuery,
ClusterBuilder builder) |
CassandraTupleOutputFormat(String insertQuery,
ClusterBuilder builder,
int maxConcurrentRequests,
java.time.Duration maxConcurrentRequestsTimeout) |