本文整理了Java中org.apache.flink.runtime.execution.Environment.getMemoryManager()
方法的一些代码示例,展示了Environment.getMemoryManager()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Environment.getMemoryManager()
方法的具体详情如下:
包路径:org.apache.flink.runtime.execution.Environment
类名称:Environment
方法名:getMemoryManager
[英]Returns the current MemoryManager.
[中]返回当前内存管理器。
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public MemoryManager getMemoryManager() {
return getEnvironment().getMemoryManager();
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public MemoryManager getMemoryManager() {
return getEnvironment().getMemoryManager();
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public void cancelTask() {
this.running = false;
try {
this.sorter.dispose();
}
catch (Exception e) {
// may happen during concurrent modification when canceling
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public void cancelTask() {
this.running = false;
try {
this.sorter.dispose();
}
catch (Exception e) {
// may happen during concurrent modification when canceling
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public void cancelTask() {
this.running = false;
try {
this.sorter.dispose();
}
catch (Exception e) {
// may happen during concurrent modification when canceling
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void cancelTask() {
this.running = false;
try {
this.sorter.dispose();
}
catch (Exception e) {
// may happen during concurrent modification when canceling
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void cancelTask() {
this.running = false;
if (this.sorter != null) {
try {
this.sorter.dispose();
}
catch (Exception e) {
// may happen during concurrent modification
}
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public void cancelTask() {
this.running = false;
if (this.sorter != null) {
try {
this.sorter.dispose();
}
catch (Exception e) {
// may happen during concurrent modification
}
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public void closeTask() throws Exception {
this.sorter.dispose();
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.combiner);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public void closeTask() throws Exception {
this.sorter.dispose();
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.combiner);
}
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void closeTask() throws Exception {
this.sorter.dispose();
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.combiner);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public void closeTask() throws Exception {
if (this.sorter != null) {
this.sorter.dispose();
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.reducer);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public void closeTask() throws Exception {
if (this.sorter != null) {
this.sorter.dispose();
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.reducer);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public void closeTask() throws Exception {
if (this.sorter != null) {
this.sorter.dispose();
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.reducer);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public void closeTask() throws Exception {
this.sorter.dispose();
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.combiner);
}
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void closeTask() throws Exception {
if (this.sorter != null) {
this.sorter.dispose();
}
this.parent.getEnvironment().getMemoryManager().release(this.memory);
if (this.running) {
BatchTask.closeUserCode(this.reducer);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public void closeTask() throws Exception {
if (sorter != null) {
sorter.dispose();
}
if (table != null) {
table.close();
}
parent.getEnvironment().getMemoryManager().release(memory);
BatchTask.closeUserCode(reducer);
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void closeTask() throws Exception {
if (sorter != null) {
sorter.dispose();
}
if (table != null) {
table.close();
}
parent.getEnvironment().getMemoryManager().release(memory);
BatchTask.closeUserCode(reducer);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public void closeTask() throws Exception {
if (sorter != null) {
sorter.dispose();
}
if (table != null) {
table.close();
}
parent.getEnvironment().getMemoryManager().release(memory);
BatchTask.closeUserCode(reducer);
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public void closeTask() throws Exception {
if (sorter != null) {
sorter.dispose();
}
if (table != null) {
table.close();
}
parent.getEnvironment().getMemoryManager().release(memory);
BatchTask.closeUserCode(reducer);
}
内容来源于网络,如有侵权,请联系作者删除!