org.apache.nifi.provenance

Class TestSchemaRecordReaderWriter

java.lang.Object

org.apache.nifi.provenance.AbstractTestRecordReaderWriter

org.apache.nifi.provenance.TestSchemaRecordReaderWriter

public class TestSchemaRecordReaderWriter
extends AbstractTestRecordReaderWriter

Constructor Summary

Constructors

Constructor and Description
TestSchemaRecordReaderWriter()

Method Summary

Modifier and Type	Method and Description
protected RecordReader	createReader(java.io.InputStream in, java.lang.String journalFilename, TocReader tocReader, int maxAttributeSize)
protected RecordWriter	createWriter(java.io.File file, TocWriter tocWriter, boolean compressed, int uncompressedBlockSize)
void	setup()
void	testAddOneRecordReadTwice()
void	testFieldAddedToSchema()
void	testFieldRemovedFromSchema()
void	testPerformanceOfRandomAccessReads()
void	testReadPerformance()
void	testWritePerformance()

Methods inherited from class org.apache.nifi.provenance.AbstractTestRecordReaderWriter

createEvent, setLogLevel, testMultipleRecordsMultipleBlocksCompressed, testMultipleRecordsSameBlockCompressed, testSimpleWriteWithToc, testSingleRecordCompressed, testSkipToEvent

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSchemaRecordReaderWriter

public TestSchemaRecordReaderWriter()

Method Detail

setup

public void setup()

testPerformanceOfRandomAccessReads

public void testPerformanceOfRandomAccessReads()
                                        throws java.lang.Exception

Throws:

java.lang.Exception

testFieldAddedToSchema

public void testFieldAddedToSchema()
                            throws java.io.IOException

Throws:

java.io.IOException

testFieldRemovedFromSchema

public void testFieldRemovedFromSchema()
                                throws java.io.IOException

Throws:

java.io.IOException

testAddOneRecordReadTwice

public void testAddOneRecordReadTwice()
                               throws java.io.IOException

Throws:

java.io.IOException

testWritePerformance

public void testWritePerformance()
                          throws java.io.IOException

Throws:

java.io.IOException

testReadPerformance

public void testReadPerformance()
                         throws java.io.IOException,
                                java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

createWriter

protected RecordWriter createWriter(java.io.File file,
                                    TocWriter tocWriter,
                                    boolean compressed,
                                    int uncompressedBlockSize)
                             throws java.io.IOException

Specified by:

createWriter in class AbstractTestRecordReaderWriter

Throws:

java.io.IOException

createReader

protected RecordReader createReader(java.io.InputStream in,
                                    java.lang.String journalFilename,
                                    TocReader tocReader,
                                    int maxAttributeSize)
                             throws java.io.IOException

Specified by:

createReader in class AbstractTestRecordReaderWriter

Throws:

java.io.IOException