public class HipoWriter
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
CUSTOMHEADER |
static int |
DICTIONARY |
Constructor and Description |
---|
HipoWriter() |
HipoWriter(java.lang.String file)
creates new Writer with an empty record store and associates with
an external file with given name.
|
Modifier and Type | Method and Description |
---|---|
void |
addHeader(java.lang.String config)
Adds string to configuration record, this record will be written the
first initiation of write operation.
|
void |
close()
destructor substitute.
|
HipoEvent |
createEvent()
Create a new HipoEvent with SchemaFactory of the writer.
|
void |
defineSchema(Schema schema) |
void |
defineSchema(java.lang.String name,
int group,
java.lang.String format) |
SchemaFactory |
getSchemaFactory()
Returns the Schema factory of the writer.
|
java.lang.String |
getStatusString()
returns a status string containing statistics for all interactions with
the writer.
|
static void |
main(java.lang.String[] args)
Main program to run internal tests and validations.
|
void |
open(java.lang.String name)
open a file and empty the record store.
|
void |
open(java.lang.String name,
byte[] array)
Opens a file, initializes it with a header.
|
void |
setCompression(boolean flag)
set compression flag for the writer, if set TRUE all records will be compressed
before being written into the file.
|
void |
setCompressionType(int type)
Sets the compression type for the records.
|
void |
setMaxRecordCount(int maxCount)
sets maximum allowed events in the record until it's flushed into
the stream.
|
void |
setMaxRecordSize(int maxSize)
sets the maximum buffer size for the records.
|
void |
write()
Writes the content of the record into the file and resets the record buffer
so new data can be added.
|
void |
writeEvent(byte[] event)
adds an event to the records, not actually written to the disk at this
point.
|
void |
writeEvent(HipoEvent event)
writes a HipoEvent into a record.
|
public HipoWriter()
public HipoWriter(java.lang.String file)
file
- public final void open(java.lang.String name)
name
- file name to write data inpublic final void open(java.lang.String name, byte[] array)
name
- name of the file to open.array
- array to write as a header.public void addHeader(java.lang.String config)
config
- public void write()
public void writeEvent(byte[] event)
event
- byte array to add to the events record.public void writeEvent(HipoEvent event)
event
- HipoEvent classpublic void close()
public java.lang.String getStatusString()
public void setCompression(boolean flag)
flag
- public void setMaxRecordCount(int maxCount)
maxCount
- maximum number of records.public void setCompressionType(int type)
type
- public void setMaxRecordSize(int maxSize)
maxSize
- maximum size in bytes for the recordpublic void defineSchema(java.lang.String name, int group, java.lang.String format)
public void defineSchema(Schema schema)
public SchemaFactory getSchemaFactory()
public HipoEvent createEvent()
public static void main(java.lang.String[] args)
args
- JHepSim. A part of HSTOOLS. version-1.2