com.streambase.sb

Class SchemaUtil.SchemaTraversal<T extends Exception>

java.lang.Object

com.streambase.sb.SchemaUtil.SchemaTraversal<T>

Enclosing class:

SchemaUtil

public abstract static class SchemaUtil.SchemaTraversal<T extends Exception>
extends Object

a class that can be used to traverse all nested schemas in a schema

Constructor Summary

Constructors

Constructor and Description
SchemaUtil.SchemaTraversal()

Method Summary

Methods

Modifier and Type	Method and Description
void	run(CompleteDataType cdt, String path)
void	run(Schema schema, String path) run the schema visitor
void	visitField(Schema.Field field, String fieldPath) This method will be called for each and every field in the schema, including nested fields and fields in lists of tuples
void	visitSchema(Schema schema, String fieldPath) This method will be called for each and every schema

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaUtil.SchemaTraversal

public SchemaUtil.SchemaTraversal()

Method Detail

visitSchema

public void visitSchema(Schema schema,
               String fieldPath)
                 throws T extends Exception

This method will be called for each and every schema

Parameters:

schema - the current schema

Throws:

StreamBaseException

T extends Exception

visitField

public void visitField(Schema.Field field,
              String fieldPath)
                throws T extends Exception

This method will be called for each and every field in the schema, including nested fields and fields in lists of tuples

Throws:

T extends Exception

run

public void run(CompleteDataType cdt,
       String path)
         throws T extends Exception

Throws:

T extends Exception

run

public void run(Schema schema,
       String path)
         throws T extends Exception

run the schema visitor

Parameters:

schema - the schema to visit

Throws:

StreamBaseException

T extends Exception