context.write(null, record); } } MapReduce任务定义，指定输入/输出类，Mapper/Recducer类，输入输出键值对格式； Job job = new Job(conf, "GroupByDemo"); HCatInputFormat

查看更多 →

为参数传递给类构造函数，或者将被引用的字段作为方法的参数传递给类构造函数。 否则，如果类或方法不包含对外部类字段的引用，则可以用类引用替换实例限定符。 单击Refactor以应用重构。 示例 作为一个例子，让我们将Inner内部类转换为嵌套的静态类。由于Inner类包含对Oute

查看更多 →

用工厂方法替换构造函数 此重构允许您用返回类实例的工厂方法替换类构造函数。 执行重构 在代码编辑器中，将光标放置在要用工厂方法替换的类构造函数上。 在主菜单或编辑器上下文菜单中，选择Refactor>Replace Constructor With Factory Method。

查看更多 →

在Select an instance expression列表中，选择要将实例方法移动到的目标类。潜在移动目标的列表包括当前类中的方法参数的类和字段的类。 为将要移动的方法添加参数名称，并将替换对当前类所有参数的引用。 在Visibility区域中，指定移动方法的可见性修改器，或选择Escalate

查看更多 →

删除事件类告警规则 功能介绍 删除一条事件类告警规则。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/event2alarm-rule 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户从IAM

查看更多 →

前提条件 已编写代码实现自定义sink类： 自定义sink类需要继承Flink开源类：RichSinkFunction，并指定数据类型为：Tuple2<Boolean, Row>。 例如开发自定义类MySink：public class MySink extends RichSinkFunction<

查看更多 →

、Hive相关数据，并进行数据拼接，通过类MultiComponentMapper继承Mapper抽象类实现。 获取拼接后的数据取最后一条输出到HBase、HDFS，通过类MultiComponentReducer继承Reducer抽象类实现。 main方法提供建立一个MapReduce

查看更多 →

委托。 Parameters Class： 在此区域中，选择是要创建新的包装参数类、在当前包装参数类中创建内部类，还是使用某些现有类。 Name：输入包装后参数的名称。 Parameters to Extract： 在此区域中，选中要提取到包装参数类的参数旁边的复选框。 单击Refactor以应用重构。

查看更多 →

主要分为三个部分： 从原文件中筛选女性网民上网时间数据信息，通过类CollectionMapper继承Mapper抽象类实现。 汇总每个女性上网时间，并输出时间大于两个小时的女性网民信息，通过类CollectionReducer继承Reducer抽象类实现。 main方法提供建立一个MapReduce

查看更多 →

源。 type_class_name 是 用户实现获取源数据的source类名称，注意包含完整包路径。 type_class_parameter 是 用户自定义source类的入参，仅支持一个string类型的参数。 注意事项 用户自定义source类需要继承类RichParal

查看更多 →

主要分为三个部分： 从原文件中筛选女性网民上网时间数据信息，通过类CollectionMapper继承Mapper抽象类实现。 汇总每个女性上网时间，并输出时间大于两个小时的女性网民信息，通过类CollectionReducer继承Reducer抽象类实现。 main方法提供建立一个MapReduce

查看更多 →

提取方法对象 此重构允许您将任意代码片段单独移动到新类的方法中，以便您可以进一步将该方法分解为同一对象上的其他方法。 执行重构 在代码编辑器中，选择要提取到包装类的新方法的代码片段。 在主菜单或编辑器上下文菜单中，选择Refactor>Extract Method Object。

查看更多 →

context.write(null, record); } } MapReduce任务定义，指定输入/输出类，Mapper/Recducer类，输入输出键值对格式； Job job = new Job(conf, "GroupByDemo"); HCatInputFormat

查看更多 →

的数据作为Flink作业的输入数据。 前提条件 自定义source类需要继承类RichParallelSourceFunction，并指定数据类型为Row。 例如自定义类MySource：public class MySource extends RichParallelSour

查看更多 →

Builder对话框中，提供重构参数。 选择是创建新的生成器类还是使用现有的生成器类。 提供生成器类名，如果创建新类，则提供其包和目标目录。 在Parameters to Pass to the Builder选项，配置作为生成器类字段传递的构造函数参数。如果指定的字段的默认值与作为构

查看更多 →

提供内部类的名称并选择是否将其创建为静态类。 在Constructor Parameters区域中，提供要用作类构造函数参数的变量的名称。使用工具栏按钮对参数重新排序。 单击Refactor以应用重构。 示例 例如，让我们将用作方法返回值的匿名类表达式转换为内部静态类MyTestClass。 重构前

查看更多 →

// 设置combiner类，默认不使用，使用时通常使用和reduce一样的类，Combiner类需要谨慎使用，也可以通过配置文件指定。 job.setCombinerClass(IntSumReducerV1.class); // 设置作业的输出类型，也可以通过配置文件指定。 job

查看更多 →

距离越长。 在火焰图中，红色表示当前实例对比值较大、绿色表示当前实例比对值较小、蓝色表示该方法、类或线程，仅在当前实例侧存在、白色表示对比值相同。 鼠标放在火焰图上，展示某一个方法、类和线程的详细信息。 单击火焰图中某个方法条，该方法条横向放大。单击“Total”列标题行，火焰图还原。

查看更多 →

、Hive相关数据，并进行数据拼接，通过类MultiComponentMapper继承Mapper抽象类实现。 获取拼接后的数据取最后一条输出到HBase、HDFS，通过类MultiComponentReducer继承Reducer抽象类实现。 main方法提供建立一个MapReduce

查看更多 →

前提条件 已编写代码实现自定义sink类： 自定义sink类需要继承Flink开源类：RichSinkFunction，并指定数据类型为：Tuple2<Boolean, Row>。 例如开发自定义类MySink：public class MySink extends RichSinkFunction<

查看更多 →

尽可能使用Interface 此重构允许您将从基类/接口派生的指定方法的执行委托给实现同一接口的父类或内部类的实例。 执行重构 在代码编辑器中，将光标放在应通过父类/接口委托其方法的类的声明上。 在主菜单或编辑器上下文菜单中，选择Refactor>Use Interface Where

查看更多 →