Flink調優 分割槽器策略

2021-10-03 01:32:35 字數 1491 閱讀 8782

控制資料流向

在流進行轉換操作後,flink通過分割槽器來精確得控制資料流向。

1.隨機分割槽器shufflepartitioner

根據均勻分布對元素進行隨機劃分

@internal

public class shufflepartitionerextends streampartitioner

@override

public streampartitionercopy()

@override

public string tostring()

}

使用使用者定義的分割槽程式為每個元素選擇目標任務。

datastream.partitioncustom(partitioner, "somekey");

datastream.partitioncustom(partitioner, 0);

全域性分割槽器globalpartitioner
@internal

public class globalpartitionerextends streampartitioner;

@override

public int selectchannels(serializationdelegate> record,

int numberofoutputchannels)

@override

public streampartitionercopy()

@override

public string tostring()

}

4.重行分割槽rebalancepartitioner分割槽元素輪循,從而為每個分割槽建立相等的負載。在存在資料偏斜的情況下對效能優化有用。

@internal

public class rebalancepartitionerextends streampartitioner;

@override

public int selectchannels(

serializationdelegate> record,

int numchannels)

return returnarray;

} private static int resetvalue(

int numchannels,

int newchannel)

return 0;

} public streampartitionercopy()

@override

public string tostring()

}

官網參

tomcat調優策略

tomcat調優問題對工作經驗兩三年的開發人員來說主要針對面試時問題 1 修改tomcat的連線模式 修改tomcat的配置檔案server.xml tomcat 聯結器的三種方式 bio nio 和 apr,三種方式效能差別很大,apr 的效能最優,bio 的效能最差。而 tomcat 7 使用的...

HIVE的調優策略

hive可以有很多方法進行調優,具體方法如下 本地模式 當要處理的資料很小時,完全分布式的啟動時間比作業時間要長時,可以使用本地模式 通過以下設定開啟本地模式 set hive.exec.mode.local.auto true default false set hive.exec.mode.lo...

SQL效能調優策略

1.建立索引 2.避免全表掃瞄 避免使用is null,is not null,這樣寫會放棄該字段的索引。如果會出現這種情況,盡量在設計表的時候設定預設值 比較操作符中 等避免使用,or 避免使用,可以使用union all進行替代 少用 in not int like萬用字元盡量將萬用字元放在後邊...