Package com.d3x.morpheus.json

Class JsonSink

java.lang.Object

com.d3x.morpheus.json.JsonSink

public class JsonSink
extends java.lang.Object

A DataFrameSink implementation that writes a DataFrame out in a Morpheus specific JSON format.

This is open source software released under the Apache 2.0 License

Author:

Xavier Witdouck

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JsonSink.Options	The options for this sink

Constructor Summary

Constructors

Constructor	Description
JsonSink()	Constructor

Method Summary

Modifier and Type	Method	Description
<R,C> void	write(com.d3x.morpheus.frame.DataFrame<R,C> frame, java.util.function.Consumer<JsonSink.Options> configurator)
private <R,C> void	writeColumn(com.d3x.morpheus.frame.DataFrame<R,C> frame, com.d3x.morpheus.frame.DataFrameColumn<R,C> column, com.google.gson.stream.JsonWriter writer, JsonSink.Options options)	Writes data for a specific column to the json writer
private <R,C> void	writerColumns(com.d3x.morpheus.frame.DataFrame<R,C> frame, com.google.gson.stream.JsonWriter writer, JsonSink.Options options)	Writes column data to the json writer
private <R,C> void	writeRowKeys(com.d3x.morpheus.frame.DataFrame<R,C> frame, com.google.gson.stream.JsonWriter writer, JsonSink.Options options)	Writes row keys to json writer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonSink

public JsonSink()

Constructor

Method Detail

write

public <R,C> void write(com.d3x.morpheus.frame.DataFrame<R,C> frame,
                        java.util.function.Consumer<JsonSink.Options> configurator)

writeRowKeys

private <R,C> void writeRowKeys(com.d3x.morpheus.frame.DataFrame<R,C> frame,
                                com.google.gson.stream.JsonWriter writer,
                                JsonSink.Options options)

Writes row keys to json writer

Parameters:

frame - the frame reference

writerColumns

private <R,C> void writerColumns(com.d3x.morpheus.frame.DataFrame<R,C> frame,
                                 com.google.gson.stream.JsonWriter writer,
                                 JsonSink.Options options)

Writes column data to the json writer

Parameters:

frame - the frame reference

writeColumn

private <R,C> void writeColumn(com.d3x.morpheus.frame.DataFrame<R,C> frame,
                               com.d3x.morpheus.frame.DataFrameColumn<R,C> column,
                               com.google.gson.stream.JsonWriter writer,
                               JsonSink.Options options)

Writes data for a specific column to the json writer

Parameters:

frame - the frame reference

column - the column reference