我是用pentaho数据集成4.4.0,并使用mongo hadoop连接器,我成功地创建了hadoop和mongo的连接。然后我安装了hive 0.11.0,使用上面的链接,我成功地创建了hive和mongo连接。在我的mongo中,包含一个数据库名称,名为pentaho,我在hive name中创建了数据库,作为demo,并使用以下命令创建了新的表名为pentho
CREATE TABLE pentaho
(
id INT,
region STRING,
year INT,
q1 INT,
q2 INT,
q3 INT,
q4 INT
)
STORED BY
我想要将多个值传递给一个pentaho数据集成转换,以便过滤最终的result.if。我想要写一个sql查询,所有我要做的就是: select field from table where name in ${parameter} the probleme我想用mongodb查询做同样的事情,但是我没有找到这样做的方法。
如果任何人有一个想法,我将非常感谢help.thanks
这就是我所想的,但它仍然不起作用:{ Nom_organisation: { $in: ["${organisation}"] } }
如果任何人对mongodb的多选参数有经验,我将不胜感激。
在表数据中,我必须从表数据中删除这些[*,=,#,&,^,%]。我不应该删除这些
使用pentaho数据将数据从mssql移动到mysql时使用特殊字符[(,),/,.,@,',",:-,_,,\]
集成
示例:-
Gujarat is the country’s largest castor oil seed producing state. The m*ajor
month’s
我正在使用五旬节数据集成,我试图连接到Hive,但是当我尝试这样做时,我得到了以下错误……
Error connecting to database [Hive] : org.pentaho.di.core.exception.KettleDatabaseException:
Error occured while trying to connect to the database
Error connecting to database: (using class org.apache.hadoop.hive.jdbc.HiveDriver)
org.apache.thrift.tran
使用戊aho5.3,Modified Java Script Value步骤注入这些数据。
我希望在MongoDB输出步骤中动态设置路径和名称。这是我的密码
var meta = new org.pentaho.di.trans.TransMeta( source_path );
var mongoStep = meta.findStep("MongoDB Output");
mongoStep.setDescription('This is MongoDB Output by Ray');
Alert(mongoStep.getName()); // cod
我有两个rackspace服务器。
服务器1使用nginx位于反向前端代理后面的应用服务器。
服务器2--刚刚安装了mongodb的服务器(有以下说明:)
我正在尝试使用类似猫鼬(在服务器1上的app.js中)连接到数据库:
// DB
var mongoose = require('mongoose');
var MongoStore = require('connect-mongo')(express);
var dbSession = 'mongodb://root:password@[Server 2]:27017'
mo
每当我从命令行而不是在Spoon UI中运行解压缩时,都会收到此错误。
Missing plugins found while loading a transformation
Step : MongoDbInput
at org.pentaho.di.job.entries.trans.JobEntryTrans.getTransMeta(JobEntryTrans.java:1200)
at org.pentaho.di.job.entries.trans.JobEntryTrans.execute(JobEntryTrans.java:643)
我使用mongodb和nodejs 8连接到数据库,但我得到了以下错误:
(node:7280) DeprecationWarning: current URL string parser is deprecated, and will be removed in a future version. To use the new parser, pass option { useNewUrlParser: true } to MongoClient.connect.
我的密码:
mongoose.connect(db,(err) => {
if (err)