public class CascadingValueWriter
extends org.elasticsearch.hadoop.serialization.builder.FilteringValueWriter<cascading.scheme.SinkCall<java.lang.Object[],?>>
JdkValueWriter that handles the unwraping of SinkCall| Constructor and Description |
|---|
CascadingValueWriter() |
CascadingValueWriter(boolean writeUnknownTypes) |
| Modifier and Type | Method and Description |
|---|---|
void |
setSettings(Settings settings) |
org.elasticsearch.hadoop.serialization.builder.ValueWriter.Result |
write(cascading.scheme.SinkCall<java.lang.Object[],?> sinkCall,
org.elasticsearch.hadoop.serialization.Generator generator) |
public CascadingValueWriter()
public CascadingValueWriter(boolean writeUnknownTypes)
public org.elasticsearch.hadoop.serialization.builder.ValueWriter.Result write(cascading.scheme.SinkCall<java.lang.Object[],?> sinkCall,
org.elasticsearch.hadoop.serialization.Generator generator)
public void setSettings(Settings settings)
setSettings in interface org.elasticsearch.hadoop.serialization.SettingsAwaresetSettings in class org.elasticsearch.hadoop.serialization.builder.FilteringValueWriter<cascading.scheme.SinkCall<java.lang.Object[],?>>