private void setSchemas ( SecorConfig config ) { Map < String , String > schemaPerTopic = config . getORCMessageSchema ( ) ; for ( Entry < String , String > entry : schemaPerTopic . entrySet ( ) ) { String topic = entry . getKey ( ) ; TypeDescription schema = TypeDescription . fromString ( entry . getValue ( ) ) ; topicToSchemaMap . put ( topic , schema ) ; // If common schema is given if ( "*" . equals ( topic ) ) { schemaForAlltopic = schema ; } } }
This method is used for fetching all ORC schemas from config