public static class FluoSparkHelper.BulkImportOptions extends Object
Modifier and Type | Field and Description |
---|---|
static FluoSparkHelper.BulkImportOptions |
DEFAULT |
Constructor and Description |
---|
BulkImportOptions() |
Modifier and Type | Method and Description |
---|---|
FluoSparkHelper.BulkImportOptions |
setAccumuloConnector(org.apache.accumulo.core.client.Connector conn)
If this methods is not called, then a Connector will be created using properties in the
FluoConfiguration supplied to
FluoSparkHelper.FluoSparkHelper(FluoConfiguration, Configuration, Path) |
FluoSparkHelper.BulkImportOptions |
setTempDir(org.apache.hadoop.fs.Path tempDir)
If this method is not called, then a temp dir will be created based on the path passed
supplied to
FluoSparkHelper.FluoSparkHelper(FluoConfiguration, Configuration, Path) |
public static FluoSparkHelper.BulkImportOptions DEFAULT
public FluoSparkHelper.BulkImportOptions setAccumuloConnector(org.apache.accumulo.core.client.Connector conn)
FluoSparkHelper.FluoSparkHelper(FluoConfiguration, Configuration, Path)
conn
- Use this connector to bulk import files into Accumulo.public FluoSparkHelper.BulkImportOptions setTempDir(org.apache.hadoop.fs.Path tempDir)
FluoSparkHelper.FluoSparkHelper(FluoConfiguration, Configuration, Path)
tempDir
- Use this directory to store RFiles generated for bulk import.Copyright © 2016–2018 The Apache Software Foundation. All rights reserved.