public static class CqlBulkRecordWriter.ExternalClient extends AbstractBulkRecordWriter.ExternalClient
Constructor and Description |
---|
CqlBulkRecordWriter.ExternalClient(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
addKnownCfs(java.lang.String keyspace,
java.lang.String cql) |
CFMetaData |
getCFMetaData(java.lang.String keyspace,
java.lang.String cfName)
Validate that
keyspace is an existing keyspace and cfName one of its existing column family. |
init
addRangeForEndpoint, getConnectionFactory, getEndpointToRangesMap, getPartitioner, setPartitioner, setPartitioner, stop
public CqlBulkRecordWriter.ExternalClient(org.apache.hadoop.conf.Configuration conf)
public void addKnownCfs(java.lang.String keyspace, java.lang.String cql)
public CFMetaData getCFMetaData(java.lang.String keyspace, java.lang.String cfName)
SSTableLoader.Client
keyspace
is an existing keyspace and cfName
one of its existing column family.getCFMetaData
in class AbstractBulkRecordWriter.ExternalClient
Copyright © 2014 The Apache Software Foundation