Modifier and Type | Class and Description |
---|---|
class |
BigQueryMarshaller<T>
An implementation of this class should serialize the objects of type T into newline separated
json as expected by the bigquery load jobs.
|
Modifier and Type | Method and Description |
---|---|
static Marshaller<ByteBuffer> |
Marshallers.getByteBufferMarshaller()
Returns a
Marshaller for ByteBuffer . |
static <T> Marshaller<T> |
Marshallers.getGenericJsonMarshaller(Class<T> type)
Returns a
Marshaller for the given type. |
static Marshaller<Integer> |
Marshallers.getIntegerMarshaller()
Returns a
Marshaller for Integers s that uses a more efficient representation
than Marshallers.getSerializationMarshaller() . |
static <K,V> Marshaller<KeyValue<K,V>> |
Marshallers.getKeyValueMarshaller(Marshaller<K> keyMarshaller,
Marshaller<V> valueMarshaller)
Returns a
Marshaller for key-value pairs based on keyMarshaller and
valueMarshaller . |
static <K,V> Marshaller<KeyValue<K,? extends Iterable<V>>> |
Marshallers.getKeyValuesMarshaller(Marshaller<K> keyMarshaller,
Marshaller<V> valueMarshaller)
Returns a
Marshaller for key-values pairs based on keyMarshaller and
valueMarshaller . |
static Marshaller<Long> |
Marshallers.getLongMarshaller()
Returns a
Marshaller for Long s that uses a more efficient representation than
Marshallers.getSerializationMarshaller() . |
static <T extends Serializable> |
Marshallers.getSerializationMarshaller()
Returns a
Marshaller that uses Java Serialization. |
static Marshaller<String> |
Marshallers.getStringMarshaller()
Returns a
Marshaller for String s. |
static Marshaller<Void> |
Marshallers.getVoidMarshaller()
Returns a
Marshaller for Void . |
Modifier and Type | Method and Description |
---|---|
static <K,V> Marshaller<KeyValue<K,V>> |
Marshallers.getKeyValueMarshaller(Marshaller<K> keyMarshaller,
Marshaller<V> valueMarshaller)
Returns a
Marshaller for key-value pairs based on keyMarshaller and
valueMarshaller . |
static <K,V> Marshaller<KeyValue<K,V>> |
Marshallers.getKeyValueMarshaller(Marshaller<K> keyMarshaller,
Marshaller<V> valueMarshaller)
Returns a
Marshaller for key-value pairs based on keyMarshaller and
valueMarshaller . |
static <K,V> Marshaller<KeyValue<K,? extends Iterable<V>>> |
Marshallers.getKeyValuesMarshaller(Marshaller<K> keyMarshaller,
Marshaller<V> valueMarshaller)
Returns a
Marshaller for key-values pairs based on keyMarshaller and
valueMarshaller . |
static <K,V> Marshaller<KeyValue<K,? extends Iterable<V>>> |
Marshallers.getKeyValuesMarshaller(Marshaller<K> keyMarshaller,
Marshaller<V> valueMarshaller)
Returns a
Marshaller for key-values pairs based on keyMarshaller and
valueMarshaller . |
MapReduceSpecification.Builder<I,K,V,O,R> |
MapReduceSpecification.Builder.setKeyMarshaller(Marshaller<K> marshaller) |
MapReduceSpecification.Builder<I,K,V,O,R> |
MapReduceSpecification.Builder.setValueMarshaller(Marshaller<V> marshaller) |
Modifier and Type | Class and Description |
---|---|
class |
BigQueryMarshallerByType<T>
Validates and generates
TableSchema of a bigquery table and marshals objects into json
for loading into that table using annotations and reflection on type T. |
class |
KeyValueMarshaller<K,V>
Marshalls KeyValue pairs given a Marshaller for the Key and the Value.
|
class |
KeyValuesMarshaller<K,V>
Marshalls KeyValue pairs where the value is an iterator.
|
Modifier and Type | Method and Description |
---|---|
static Marshaller |
InProcessUtil.getKeyMarshaller(MapReduceSpecification spec) |
Modifier and Type | Method and Description |
---|---|
static <T> SerializableValue<T> |
SerializableValue.of(Marshaller<T> marshaller,
T value) |
static <T> T |
SerializationUtil.readObjectFromObjectStreamUsingMarshaller(Marshaller<T> marshaller,
ObjectInputStream oin) |
static <T> void |
SerializationUtil.writeObjectToOutputStreamUsingMarshaller(T object,
Marshaller<T> marshaller,
ObjectOutputStream oout) |
Modifier and Type | Method and Description |
---|---|
Marshaller<T> |
UnmarshallingInputReader.getMarshaller() |
Constructor and Description |
---|
PeekingInputReader(InputReader<ByteBuffer> reader,
Marshaller<T> marshaller) |
UnmarshallingInput(Input<ByteBuffer> input,
Marshaller<I> marshaller) |
UnmarshallingInputReader(InputReader<ByteBuffer> reader,
Marshaller<T> marshaller) |
Constructor and Description |
---|
MarshallingOutput(Output<ByteBuffer,R> sink,
Marshaller<O> marshaller) |
MarshallingOutputWriter(OutputWriter<ByteBuffer> writer,
Marshaller<? super O> marshaller) |
ShardingOutputWriter(Marshaller<K> keyMarshaller,
Sharder sharder) |
Copyright © 2015 Google. All rights reserved.