import parquet.io.api.RecordConsumer; //导入依赖的package包/类
public void writeRow( RowMetaAndData row, RecordConsumer consumer ) {
  consumer.startMessage();
  int index = 0;
  for ( SchemaDescription.Field f : schema ) {
    if ( f.formatFieldName == null ) {
      continue;
    }
    try {
      writeField( f, index, row, consumer );
      index++;
    } catch ( KettleValueException ex ) {
      throw new RuntimeException( ex );
    }
  }
  consumer.endMessage();
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
public void setUp(MessageType schema, RecordConsumer consumer) {
  this.schema = schema;
  this.consumer = consumer;
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
public TupleWriter(RecordConsumer recordConsumer, GroupType schema) {
    this.recordConsumer = recordConsumer;
    this.schema = schema;
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
public void prepareForWrite(RecordConsumer recordConsumer) {
    writer = new TupleWriter(recordConsumer, schema);
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
@Override
public void prepareForWrite(RecordConsumer recordConsumer) {
    groupWriter = new GroupWriter(recordConsumer, schema);
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
@Override
public void prepareForWrite(RecordConsumer recordConsumer) {
    delegate.prepareForWrite(recordConsumer);
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
public void writeValue(int field, int index, RecordConsumer recordConsumer) {
  ((Primitive) this.getValue(field, index)).writeValue(recordConsumer);
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
@Override
public void prepareForWrite(RecordConsumer recordConsumer) {
  this.recordConsumer = recordConsumer;
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
@Override
public void prepareForWrite( RecordConsumer recordConsumer ) {
  consumer = recordConsumer;
}
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
/**
 * This will be called once per row group
 *
 * @param recordConsumer the recordConsumer to write to
 */
public abstract void prepareForWrite(RecordConsumer recordConsumer);
 

import parquet.io.api.RecordConsumer; //导入依赖的package包/类
/**
 * Called once per row group.
 *
 * @param recordConsumer The {@link RecordConsumer} to write to.
 */
@Override
public void prepareForWrite(RecordConsumer recordConsumer) {
  this.recordConsumer = recordConsumer;
}