Package io.deephaven.enterprise.merge.impl.deephaven

Class ParquetMergeDestinationWriter

java.lang.Object

io.deephaven.enterprise.merge.impl.deephaven.MergeDestinationWriter

io.deephaven.enterprise.merge.impl.deephaven.ParquetMergeDestinationWriter

public class ParquetMergeDestinationWriter
extends MergeDestinationWriter

A MergeDestinationWriter implementation which writes TableLocation.Format.PARQUET to disk. The current parquet-writing implementation (see ParquetTools.writeTable(Table, String)) does not permit for multiple row-groups, so we unfortunately need to collect and merge all sub-tables and write in a single call

Field Summary

Fields inherited from class io.deephaven.enterprise.merge.impl.deephaven.MergeDestinationWriter

columnPartitionValue, destinationTable, destinationTableSize, MERGE_TEMP_COREPLUS_PREFIX, mergeData, permanentDirectory, PRE_MERGE_CHUNKS, temporaryDirectory, writableInternalPartition, WRITE_CHUNK_SIZE

Method Summary

Methods inherited from class io.deephaven.enterprise.merge.impl.deephaven.MergeDestinationWriter

getGroupCols

Methods inherited from class java.lang.Object

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