控制資料流向
在流進行轉換操作後,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萬用字元盡量將萬用字元放在後邊...