Class ShardedWriter.PowerOf2ShardedConsumer<T>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, ToFileWriter<T>
    Enclosing class:
    ShardedWriter<T>

    static final class ShardedWriter.PowerOf2ShardedConsumer<T>
    extends ShardedWriter<T>
    • Field Detail

      • myDistributor

        private final java.util.function.ToIntFunction<T> myDistributor
      • myIndexMask

        private final int myIndexMask
    • Constructor Detail

      • PowerOf2ShardedConsumer

        PowerOf2ShardedConsumer​(java.util.function.ToIntFunction<T> distributor,
                                ToFileWriter<T>[] consumers)
    • Method Detail

      • write

        public void write​(T item)
        Description copied from interface: ToFileWriter
        Write the item to the consumer.
        Parameters:
        item - The item to be written