Technology sharing

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1 Overview

1. Facite configuratione

StreamExecutionEnvironment ContinetExecutionConfig, quod permittit officium configurationis specialium valorum qui tempore currenti constituendi sunt.

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
ExecutionConfig executionConfig = env.getConfig();

Haec sunt optiones configuratione praesto: (audax per default)

• setClosureCleanerLevel() . Claustrum mundius gradu ponitur per defaltamClosureCleanerLevel.RECURSIVE . Clausurae mundior notationes necessarias removet ad munus anonymi vocantis classes in programmate Flink. Post inactivare clausuram mundioris, munus anonymi usoris potest significare quaedam vocationis non-serializabilia classis. Hoc serializer exceptionem mittet. Valores stabilis sunt:NONE: Claustrum mundius omnino disable,TOP_LEVEL: tantum munditias summo-gradu classes sine recursura in agros;RECURSIVE: Munda omnia campis recursively.
• getParallelism() / setParallelism(int parallelism) . Defectus gradus ponit parallelismi pro jobs.
• getMaxParallelism() / setMaxParallelism(int parallelism) . Defaltam maximam parallelismus ponit pro jobs. Hic occasus maximum gradum parallelismi determinat ac superiorem ligamen in scalis dynamicis designat.
• getNumberOfExecutionRetries() / setNumberOfExecutionRetries(int numberOfExecutionRetries) . Pone pluries incassum munia re- percussa sunt. Valor nullius efficacius tolerantiae culpam priuat.-1 Defaltis per systema indicat (in configuratione definitur).Configuratio haec deprecatur, quaeso utere sileo consilio potius.
• getExecutionRetryDelay() / setExecutionRetryDelay(long executionRetryDelay) . Moram (in milliseconds) systema manet antequam re-exsecutionis officium postquam deficit. Postquam omnia opera in TaskManagers feliciter cessaverunt, mora computata est et semel dilatio praeteriit, opera reprimuntur.Configuratio haec deprecata est, quaeso utere sileo consilio potius.
• getExecutionMode() / setExecutionMode() . Defectus exsecutionis modus est PIPELINED. Modus exsecutionis constitue ad faciendam progressio. Executio modum definit utrum data commutatio fiat in batch an modus effusis.
• enableForceKryo() / disableForceKryo . Kryo defalta adhiberi non cogitur. Copiae GenericTypeInformationes utendi Kryo serializer pro POJOs, etiamsi POJOs partiri possunt. In quibusdam, ut haec conformatio praeferenda sit. Exempli gratia, cum Flink internus serializer non recte tractat POJOs.
• enableForceAvro() / disableForceAvro() . Avro defaltam poni non cogitur. Force Flink AvroTypeInfo uti Avro serializer loco Kryo ad serialize Avro POJOs.
• enableObjectReuse() / disableObjectReuse() . Defalta obiecti in Flink non reddi. Enabling objectum reuse modus docet runtime ad reuse objecta usoris melioris effectus. Nota quod cimices faciant.
• getGlobalJobParameters() / setGlobalJobParameters() . Haec methodus permittit utenti ut obiectum consuetudinis in configurationis globalis operis.quodExecutionConfig Accessibilis in omnibus functionibus usoris definitis, ergo haec est facilis via ad figuras globally per jobs efficiendas.
• addDefaultKryoSerializer(Class type, Serializer serializer) . Exemplum Kryo serializer registrat ad certum genus.
• addDefaultKryoSerializer(Class type, Class
  上一篇 下一篇