org.apache.accumulo.examples.simple.filedata
public class FileDataIngest extends Object
Modifier and Type | Class and Description |
---|---|
static class |
FileDataIngest.Opts |
Modifier and Type | Field and Description |
---|---|
static org.apache.hadoop.io.Text |
CHUNK_CF |
static ByteSequence |
CHUNK_CF_BS |
static org.apache.hadoop.io.Text |
REFS_CF |
static ByteSequence |
REFS_CF_BS |
static String |
REFS_FILE_EXT |
static String |
REFS_ORIG_FILE |
Constructor and Description |
---|
FileDataIngest(int chunkSize,
ColumnVisibility colvis) |
Modifier and Type | Method and Description |
---|---|
static int |
bytesToInt(byte[] b,
int offset) |
String |
hexString(byte[] bytes) |
String |
insertFileData(String filename,
BatchWriter bw) |
static byte[] |
intToBytes(int l) |
static void |
main(String[] args) |
public static final org.apache.hadoop.io.Text CHUNK_CF
public static final org.apache.hadoop.io.Text REFS_CF
public static final String REFS_ORIG_FILE
public static final String REFS_FILE_EXT
public static final ByteSequence CHUNK_CF_BS
public static final ByteSequence REFS_CF_BS
public FileDataIngest(int chunkSize, ColumnVisibility colvis)
public String insertFileData(String filename, BatchWriter bw) throws MutationsRejectedException, IOException
public static int bytesToInt(byte[] b, int offset)
public static byte[] intToBytes(int l)
public String hexString(byte[] bytes)
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.