Messtone LLC Manages(Pattern):

Developer.here.com Messtone Pattern matching in Scala: val processingType=driverContext.jobVersions.inCatalogs(id)Val version=processingType match {case NoChanges(v)=>v case Changes(_,v)=>v case Reprocess(v)=>v} ProcessingType processingType=driverContext.jobVersions( ).inCatalogs( ).get(id);long version;if(processingType instanceof NoChanges){version=((NoChanges)processingType).version( );}else if(processingType instanceof Changes){version=((Changes)processingType).version( );}else if(processingType instanceof Reprocess){version=((Reprocess) processingType.version( );}else{throw new RunTimeException(“Match error”);} val logger=new ContextAwareLogger(getClass)//or use the one provided by ContextLogging LogContext.withChild(“my-context-id”,id){val payload=Retriever.getPayLoad(in.key,in.meta)logger.debug(s”Retrieved ${payload.length}bytes”)} ContextAwareLogger logger=new ContextAwareLogger(getClass( ));LogContext.withChild(“my-context-id”,id,( )->{Payload payload=Retriever.getPayload(in.getKey( ),in.getValue( ));logger.debug(“Retrieved { } bytes”,payload.length( ));});Scala class Tags: def buildTask(driverBuilder:DriverBuilder,compiler: Direct1ToNCompiler[IntermediateData]):val taskBuilder=driverBuilder.newTaskBuilder(“task1”) taskBuilder.withDirect1ToNCompiler(compiler).build( )}DriverTask buildTask(DriverBuilder driverBuilder, Direct1ToNCompiler<IntermediateData>compiler){TaskBuilder taskBuilder=driverBuilder.newTaskBuilder(“task1”);return taskBuilder.withDirect1ToNCompiler(compiler,IntermediateData.class).build( );}

Leave a comment